package org.geektimes.reactive.streams.simple;

import org.reactivestreams.Subscription;

/**
 * @FileName: DefaultSubscription
 * @Description: TODO
 * @Author: MaWenHao
 * @Created: 2021/3/30 - 下午11:13
 */
public class DefaultSubscription implements Subscription {

    private boolean canceled = false;

    @Override
    public void request(long n) {

    }

    @Override
    public void cancel() {
        this.canceled = true;
    }

    public boolean isCanceled() {
        return canceled;
    }
}
